package com.we.flink.userlabelplatform.table;

import java.sql.Timestamp;

public class TableVerifyUserLineExt {
    public static final String KFKTABLE = "fdm.ris10_verify_user_line_ext";
    public static final String QUERYSQL =
            "select user_key, lift_amount, "
                    + "if(tmp_expire_time is null, '2303654400000', tmp_expire_time) tmp_expire_time, "
                    + "update_time "
                    + "from "
                    + KFKTABLE
                    + "  where lift_type is not null and lift_amount > 0 and update_time is not null ";

    public String user_key;
    public float lift_amount;
    public String tmp_expire_time;
    public Timestamp update_time;

    public TableVerifyUserLineExt() {}

    public TableVerifyUserLineExt(
            String user_key, float lift_amount, String tmp_expire_time, Timestamp update_time) {
        this.user_key = user_key;
        this.lift_amount = lift_amount;
        this.tmp_expire_time = tmp_expire_time;
        this.update_time = update_time;
    }

    public String getUser_key() {
        return user_key;
    }

    public float getLift_amount() {
        return lift_amount;
    }

    public String getTmp_expire_time() {
        return tmp_expire_time;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }

    @Override
    public String toString() {
        return "TableVerifyUserLineExt{"
                + "user_key='"
                + user_key
                + '\''
                + ", lift_amount="
                + lift_amount
                + ", tmp_expire_time='"
                + tmp_expire_time
                + '\''
                + ", update_time="
                + update_time
                + '}';
    }
}
